package test.serverframe.armc.server.manager.service.exec.params;

import java.util.concurrent.atomic.AtomicInteger;

import test.serverframe.armc.server.manager.service.exec.dag.DagNode;

/**
 * 任务执行器参数
 *
 * @author LiuChunfu
 * @date 2019.01.19
 */
public class TaskExecutorParams {

    /**
     * 任务ID
     */
    private String taskId;

    //任务执行总数
    private AtomicInteger taskTotal;

    //任务执行成功总数
    private AtomicInteger successTaskTotal;

    /**
     * 预期任务执行总数
     */
    private int expectedTaskTotal;

    //调度记录id
    private String invokeRecordId;
    
    private DagNode dagNode;
    
    private String failedStrategy;
    
    private String taskRecordId;
    
    private String taskInvokeId;
    
    private Boolean isReStart;
    
    public String getTaskId() {
        return taskId;
    }

    public void setTaskId(String taskId) {
        this.taskId = taskId;
    }

    public AtomicInteger getTaskTotal() {
        return taskTotal;
    }

    public void setTaskTotal(AtomicInteger taskTotal) {
        this.taskTotal = taskTotal;
    }

    public AtomicInteger getSuccessTaskTotal() {
        return successTaskTotal;
    }

    public void setSuccessTaskTotal(AtomicInteger successTaskTotal) {
        this.successTaskTotal = successTaskTotal;
    }

    public String getInvokeRecordId() {
        return invokeRecordId;
    }

    public void setInvokeRecordId(String invokeRecordId) {
        this.invokeRecordId = invokeRecordId;
    }

    public int getExpectedTaskTotal() {
        return expectedTaskTotal;
    }

    public void setExpectedTaskTotal(int expectedTaskTotal) {
        this.expectedTaskTotal = expectedTaskTotal;
    }

	public DagNode getDagNode() {
		return dagNode;
	}

	public void setDagNode(DagNode dagNode) {
		this.dagNode = dagNode;
	}

	public String getFailedStrategy() {
		return failedStrategy;
	}

	public void setFailedStrategy(String failedStrategy) {
		this.failedStrategy = failedStrategy;
	}

	public String getTaskRecordId() {
		return taskRecordId;
	}

	public void setTaskRecordId(String taskRecordId) {
		this.taskRecordId = taskRecordId;
	}

	public String getTaskInvokeId() {
		return taskInvokeId;
	}

	public void setTaskInvokeId(String taskInvokeId) {
		this.taskInvokeId = taskInvokeId;
	}

	public Boolean getIsReStart() {
		return isReStart;
	}

	public void setIsReStart(Boolean isReStart) {
		this.isReStart = isReStart;
	}

}
